a0c37a5161a0c1a6dd4c4b5886025a9b12524867,nakadi-java-client/src/main/java/nakadi/OkHttpResource.java,OkHttpResource,requestThrowing,#String#String#ResourceOptions#Class#,116

Before Change


  public <Res> Res requestThrowing(String method, String url, ResourceOptions options,
      Class<Res> res) throws NakadiException {

    if (null == retryPolicy) {
      Response response = requestThrowingInner(method, url, options);
      return marshalResponse(response, res);
    } else {
      Observable<Response> observable = Observable.defer(
          () -> Observable.just(requestThrowingInner(method, url, options))
      ).compose(buildRetry(retryPolicy));

      Response response = observable.toBlocking().first();
      return marshalResponse(response, res);

After Change


  public <Res> Res requestThrowing(String method, String url, ResourceOptions options,
      Class<Res> res) throws NakadiException {

    Observable<Response> observable =
        Observable.defer(() -> Observable.just(requestThrowingInner(method, url, options)));

    Response response = maybeComposeRetryPolicy(observable).toBlocking().first();
    return marshalResponse(response, res);
  }